//package com.caocaog.market.toccpt.rabbitmq;
//
//import com.rabbitmq.client.ConnectionFactory;
//import lombok.extern.slf4j.Slf4j;
//
///**
// * @author liguang
// * @version 1.0.0
// * @Project jeecg-boot
// * @Package com.caocaog.market.toccpt.rabbitmq
// * @ClassName RabbitMQUtil.java
// * @createTime 2021年12月31日 09:44:00
// * @Description TODO
// */
//@Slf4j
//public class RabbitMQUtil {
//    private static ConnectionFactory factory;
//
//    static {
//        factory = initConnectionFactory();
//    }
//
//    private RabbitMQUtil() {
//    }
//
//    public static ConnectionFactory getRabbitMQConnectionFactory() {
//        if (null != factory) {
//            return factory;
//        }
//        log.info("rabbitMQ没有连接成功，即将重新连接！");
//        return initConnectionFactory();
//    }
//
//    public static ConnectionFactory initConnectionFactory() {
//        try {
//            /* 使用工厂类建立Connection和Channel，并且设置参数 */
//            factory = new ConnectionFactory();
//            factory.setHost("39.106.214.219");
//            factory.setPort(5672);
//            factory.setUsername("admin");
//            factory.setPassword("ccpt2020");
//        } catch (Exception e) {
//            log.info("连接RabbitMQ出错，连接信息：host:39.106.214.219   port：5672 username:admin   password:ccpt2020" + e.getMessage());
//        }
//        return factory;
//    }
//
//    /*public static void main(String[] args) {
//        for (int i = 0; i < 8; i++) {
//            ConnectionFactory rabbitMQConnection = getRabbitMQConnection();
//        }
//    }*/
//}
